/*
 * Test terminal target: Kafka 接受数据并消费到hbase数据库
 * Class:测试消费者
 * 
 * Author： Ricky Lin 
 * Data: 2017-08-01
 * 
 */

package com.kafka.hbase;

import org.apache.log4j.PropertyConfigurator;

public class Kafkaceshi {

	public static void main(String[] args) {
		
		System.out.println(System.getProperty("user.dir"));
    	String path = System.getProperty("user.dir");
    	String log4jConfPath = path+"\\src\\main\\resources\\log4j.properties";
    	PropertyConfigurator.configure(log4jConfPath);
		
//      KafkaProducer a=new KafkaProducer ();
//      a.producer();
        KafkaConsumer consumerThread = new KafkaConsumer(KafkaProperties.topic); 
        consumerThread.run();
 
    }
}
